#ifndef __CONSUMER_THREAD_H__
#define __CONSUMER_THREAD_H__

#include "thread.hpp"


namespace rocket 
{
class pool;
class consumer_thread
:public thread
{
public:
    consumer_thread(pool *);

private:
    void execute();

private:
    pool *_pool;
};

}




#endif